package com.syf.starter.kafka.config;

import com.syf.core.engine.SyFrameContext;
import com.syf.starter.kafka.SyKafkaCustomerServer;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * Kafka Consumer Server自动配置类
 */
@Configuration
@EnableConfigurationProperties(SyKafkaCustomerServerConfiguration.class)
public class SyKafkaCustomerServerStarterAutoConfig {

    @Bean
    public SyKafkaCustomerServer syKafkaCustomerServer(SyKafkaCustomerServerConfiguration configuration,
                                                       SyFrameContext syFrameContext) {
        return new SyKafkaCustomerServer(configuration, syFrameContext);
    }
} 